from kafka import KafkaConsumer

# consumer = KafkaConsumer(bootstrap_servers=["192.168.10.130:9092"],
#                          enable_auto_commit=True,auto_commit_interval_ms=5000)
# consumer.subscribe(['story_product_chapter_topic'])
# for msg in consumer:
#     print(msg.topic,msg.partition,msg.offset,msg.value)

from kafka import KafkaProducer

producer = KafkaProducer(bootstrap_servers=["192.168.10.130:9092"])
producer.send('already_product_topi_2', b'Hello, Kafka!')
